<?php

declare(strict_types=1);
/**
 * This file is part of Hyperf.
 *
 * @link     https://www.hyperf.io
 * @document https://hyperf.wiki
 * @contact  group@hyperf.io
 * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
 */

return [
    'enabled' => false,
    'mapping' => [
        'default' => [
            'driver' => \JfbQueue\Driver\RedisStreamDriver::class,
            'redis' => [
                'pool' => 'default',
            ],
            'group' => 'lcmqgroup11',
            'stream' => [
                'key' => 'lcmq1',
                'id' => '>'
            ],
            'handle_timeout' => 30, // 处理超时时间
            'max_attempts' => 5, // 最大消费次数
            'wait_seconds' => 10, // 接收消息时等待时长 不要超过redis的 max_idle_time 时长
            'batch_size' => 10, // 批量取消息大小
            'processes' => \Hyperfx\Utils\AppEnvUtil::isProd() ? 4 : 2,
            'max_messages' => 2000,
            'is_reload' => true, // 发送端请设置为false
        ],
    ]
];
